package com.shujia.userprofile.behavior.order

import com.shujia.util.SparkRunner
import org.apache.spark.sql.{DataFrame, SparkSession}

object OrderTimeUserTag  extends SparkRunner{
  fieldName = "orderTime"
  override def fetchTgg(spark: SparkSession, ds: String): DataFrame = {

    spark.sql(
      s"""
        |select
        |member_id as id,
        | max(create_time) as orderTime
        | from
        |dwd.dwd_order_info_d_f
        |where ds='$ds'
        |group by member_id
        |
        |""".stripMargin)
  }
}
